Skip to content

Announce Flink Agents 0.4.0 - #888

Merged
wenjin272 merged 2 commits into
apache:asf-sitefrom
wenjin272:flink-agents-040
Oct 30, 2026
Merged

wenjin272 merged 2 commits into
apache:asf-sitefrom
wenjin272:flink-agents-040

Conversation

@wenjin272

Copy link
Copy Markdown
Contributor

Announce Flink Agents 0.4.0

@xintongsong xintongsong left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks for preparing this, @wenjin272 . LGTM.

I left a few minor comments. In addition to them, I think we can add more links from the brief feature descriptions to the detailed documentations.


The Apache Flink community is excited to announce the release of Apache Flink Agents 0.4.0.

Apache Flink Agents brings AI agents into Flink streaming pipelines. Applications can continuously respond to real-time events, combine AI reasoning with business logic, and use Flink for distributed execution and fault recovery.

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think Flink Agents can do more than just reasoning.

Suggested change
Apache Flink Agents brings AI agents into Flink streaming pipelines. Applications can continuously respond to real-time events, combine AI reasoning with business logic, and use Flink for distributed execution and fault recovery.
Apache Flink Agents brings AI agents into Flink streaming pipelines. Applications can continuously respond to real-time events, combine AI processing with business logic, and use Flink for distributed execution and fault recovery.


#### Model Routing: Choose the Right Model for Each Request

**Model Routing** dynamically selects a model for each request from a set of candidates, using rule-based matching, an LLM judge, or custom routing logic. For example, an application can use a smaller model for routine requests and a more capable model for complex tasks. Model Routing is currently available through the Java programmatic API.

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
**Model Routing** dynamically selects a model for each request from a set of candidates, using rule-based matching, an LLM judge, or custom routing logic. For example, an application can use a smaller model for routine requests and a more capable model for complex tasks. Model Routing is currently available through the Java programmatic API.
**Model Routing** dynamically selects a model for each request from a set of candidates, using rule-based matching, an LLM judge, or custom routing logic. For example, an application can use a lightweight model for routine requests and a more capable model for complex tasks. Model Routing is currently available through the Java programmatic API.

@weiqingy weiqingy left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks for putting this together. I checked the download entries, the docs links and anchors, and the defaults in the breaking-changes section against the release-0.4.0-rc1 tag, and they all match. One question inline.


- **Chat Models:** [Google Gemini](https://nightlies.apache.org/flink/flink-agents-docs-release-0.4/docs/development/calling-llms/chat-models/providers/#gemini) for Java, and [vLLM](https://nightlies.apache.org/flink/flink-agents-docs-release-0.4/docs/development/calling-llms/chat-models/providers/#vllm) and [IBM watsonx.ai](https://nightlies.apache.org/flink/flink-agents-docs-release-0.4/docs/development/calling-llms/chat-models/providers/#watsonx-ibm-watsonxai) for Java and Python.
- **Embedding Models:** [OpenAI embeddings](https://nightlies.apache.org/flink/flink-agents-docs-release-0.4/docs/development/vector-search/embedding_models/providers/#openai) for Java.
- **Flink versions:** A distribution for Flink 2.3.

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Flink 2.3 isn't new in 0.4. The distribution shipped in 0.3.1 (apache/flink-agents#856), and the 0.3.1 announcement already lists "Flink 2.3 distribution support", so users upgrading from 0.3.1 already have it. Maybe we can drop this bullet, and the heading on line 81 could become "More Model Integrations". What do you think?


Visit the [Apache Flink downloads page](https://flink.apache.org/downloads/#apache-flink-agents-040) for release artifacts. For guidance on building, deploying, and operating agents, see the [Flink Agents documentation](https://nightlies.apache.org/flink/flink-agents-docs-release-0.4/).

We welcome feedback on the applications you are building, the capabilities you need, and any problems you encounter. Submit feature requests and bug reports through [GitHub Issues](https://github.com/apache/flink-agents/issues), or share use cases and ideas in [GitHub Discussions](https://github.com/apache/flink-agents/discussions).

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I would suggest that we call out the slack channel #flink-agents-user is another way to provide feedbacks.

@alnzng alnzng left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@wenjin272
wenjin272 merged commit 18807d5 into apache:asf-site Oct 30, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants